package com.redis.study.stream.run;

import lombok.Data;

import java.util.List;

/**
 *  模拟Stream对应的组
 */
@Data
public class StreamEntity {
    // key
    private String keyName;

    // 组
    private List<Group> groups;

}
/**
 *  模拟Stream对应的组中的消费者
 */
@Data
class Group{
    // 组名
    private String groupName;
    // 消费者
    private List<String> consumers;
}
